package com.zzs.client.rabbit;

/**
 * @author zzs
 * @date 2025/04/01
 */
//@Component
public class MqListener {
//    private int count = 0;
//    private int count1 = 0;
////    @RabbitListener(queues = "oj_task_queue")
//    public void listen(String message) throws InterruptedException {
//        System.out.println("A: " + message + ", 计数: " + (++count));
//        Thread.sleep(100);
//    }
//
////    @RabbitListener(queues = "oj-java-queue")
//    public void listen1(String message) throws InterruptedException {
//        System.err.println("oj-java-queue: " + message + ", 计数: " + (++count1));
//        Thread.sleep(50);
//    }
//
////    @RabbitListener(bindings = @QueueBinding(
////            value = @Queue(name = "oj-java-queue"),
////            exchange = @Exchange(name = "oj.direct", type = ExchangeTypes.DIRECT),
////            key = {"java"}
////    ))
//    public void listen2(Student msg) {
//        System.out.println(msg);
//    }
}
